package org.common.utils.consumer;

/**
 * 消费者组工厂
 * @author zhouzhibing
 * @date 2025/8/5
 */
public class ConsumerGroupFactory {


    /**
     * 创建消费者组
     * @param config 配置
     * @return 消费者组
     */
    public static ConsumerGroup ofQueue(ConsumerConfig config) {
        return new ConsumerGroup(config);
    }

    /**
     * 创建一个唯实体的，重复id实体，则不会多次添加，消费者组
     * @param config 配置
     * @return 消费者组
     */
    public static ConsumerMapGroup ofMapQueue(ConsumerConfig config) {
        return new ConsumerMapGroup(config);
    }
}
